
import time
import random
import multiprocessing


# 3）进程池之间使用 Manager().Queue 通信
# 间隔随机时间向queue中放入随机数
def func1(queue):
     for i in range(5):
          queue.put(i)
          print(i)
          time.sleep(2)

# 从queue中取出数据
def func2(queue):
     for i in range(5):
          print(queue.get())

if __name__ == "__main__":
     queue = multiprocessing.Manager().Queue()
     pool = multiprocessing.Pool(2)
     pool.apply_async(func1, (queue,))
     pool.apply_async(func2, (queue,))
     pool.close()
     pool.join()